package com.ruoyi.mqtt.service;


import com.ruoyi.mqtt.domain.bo.SysMqttBo;

import java.util.List;
import java.util.Map;

/**
 * MQTT 服务层
 *
 * @author 曾午
 */
public interface ISysMqttService {

    /**
     * 获取当前所有topic列表
     */
    List<Map<String, Object>> getTopics();

    /**
     * 发送消息到指定topic
     */
    void sendMsgToTopic(SysMqttBo mqttBo);

    /**
     * 动态新增topic
     */
    void addTopic(SysMqttBo mqttBo);

    /**
     * 动态移除topic
     */
    void removeTopic(SysMqttBo mqttBo);
}
